package com.bigdata.spark.sparkstreaming.job;

import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.streaming.Duration;
import org.apache.spark.streaming.api.java.JavaStreamingContext;

import com.bigdata.spark.common.SparkJob;

public class WordCountJob extends SparkJob {

	public static void main(String[] args) {

	}

	@Override
	public void execute(JavaSparkContext sparkContext, String[] args) {
		super.execute(sparkContext, args);
	}

	private void deal() {
		SparkConf sparkConf = new SparkConf().setMaster("local[4]").setAppName("test");

		JavaStreamingContext streamingContext = new JavaStreamingContext(sparkConf, Duration.apply(1000));

	}
}
